package com.hadwinling.alogriithm.core.rdd.buider

import org.apache.spark.{SparkConf, SparkContext}

object Spark01_RDD_Memory_Par01 {
  def main(args: Array[String]): Unit = {
    //TODO
    val conf = new SparkConf().setMaster("local[*]").setAppName("RDD")
    val sc = new SparkContext(config = conf)

    // TODO 创建RDD
    // 【1，2】，【3，4】
    //val rdd = sc.makeRDD(List(1,2,3,4), 2)
    // 【1】，【2】，【3，4】
    //val rdd = sc.makeRDD(List(1,2,3,4), 3)
    // 【1】，【2,3】，【4,5】
    val rdd = sc.makeRDD(List(1, 2, 3, 4, 5), 3)


    //todo 将处理的数据保存成分区文件
    rdd.saveAsTextFile("output")


    // TODO 关闭环境
    sc.stop()

  }

}
